package com.scs.application.modules.msg.ram;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * @description: E 需要实现序列化
 *
 */
public class LesonQueue<E> {
    private int size = 1; //
    protected int MAX_VALUE = 1024 * size;
    protected BlockingQueue<E> store = null;

    LesonQueue(){
        this.store = new LinkedBlockingQueue<E>(MAX_VALUE);
    }

    LesonQueue(BlockingQueue<E> store){
        this.store = store;
    }

}
